# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dm.dm_waybill_reback_sender_detail_dt import jms_dm__dm_waybill_reback_sender_detail_dt

# 拦截退转中类型退回始发网点明细数据（T-1）
oss__waybill_reback_sender_detail = BashOperator(
    task_id='oss__waybill_reback_sender_detail',
    email=['guoruiling@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/waybill_reback_sender_detail/execute.sh',
    execution_timeout=timedelta(minutes=10),
    sla=timedelta(hours=7)
)

oss__waybill_reback_sender_detail << [ jms_dm__dm_waybill_reback_sender_detail_dt ]
